package util;

import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;

/**
 * 在界面初始化时创建文件信息数据表
 */
public class DBInit {
    /**
     * 从resources路径下读取init.sql文件，加载到程序中
     * 文件IO
     *
     */

    public static List<String> readSQL(){
        List<String> ret = new ArrayList<>();
        //init.sql文件中获取内容，需要拿到文件的输入流
        try {
            //采用类加载器的方式引入资源文件
            //JVM在加载类的时候用到的ClassLoder类
            InputStream in = DBInit.class.getClassLoader().
                    getResourceAsStream("init.sql");
        //对于输入流来说，一律采用Scanner类来处理
            //对于输出流来说，一律采用PrintStream类来处理
            //之前如何输入输出的，键盘和显示器
            //现在也是如此
            //从文件获取输入流
            Scanner scanner = new Scanner(in);
            //自定义分隔符
            scanner.useDelimiter(";");
            //nextLine默认碰到换行分隔
            //next按照自定义的分隔符拆分
            while (scanner.hasNext()){
                String str = scanner.next();
                if ("".equals(str) || "\n".equals(str)){
                    continue;
                }
                if (str.contains("--")){
                    str = str.replaceAll("--","");
                }
                ret.add(str);
            }
        }catch (Exception e){
            throw  new RuntimeException(e);
        }

        return ret;
    }


    /**
     * 在界面初始化时先初始化数据库 创建数据表
     */
    public  static void init(){
        Connection connection = null;
        Statement statement = null;
        try {
            connection = DBUtil.getConnection();
            //获取要执行的sql语句
            List<String> sqls = readSQL();
            // 这里咱采用了普通的Statement接口，没有用PrepareStatement
            statement = connection.createStatement();
            for (String sql : sqls){
                System.out.println("执行SQL操作 ： " +sql);
                statement.executeUpdate(sql);
            }
        }catch (SQLException e){
            System.err.println("数据库初始化失败");
            e.printStackTrace();
        }finally {
            DBUtil.close(statement);
        }
    }
}
